ceaef105323d031ef92751d2744ad7a0f0be2c08,components/camel-aws/src/main/java/org/apache/camel/component/aws/ddbstream/DdbStreamConsumer.java,DdbStreamConsumer,getShardItertor,#,96

Before Change



            GetShardIteratorRequest req = new GetShardIteratorRequest()
                    .withStreamArn(streamArn)
                    .withShardId(res1.getStreamDescription().getShards().get(0).getShardId()) // XXX only uses the first shard
                    .withShardIteratorType(getEndpoint().getIteratorType())
                    ;
            GetShardIteratorResult result = getClient().getShardIterator(req);

After Change


                    .withStreamArn(streamArn)
                    ;
            DescribeStreamResult res1 = getClient().describeStream(req1);
            shardList.addAll(res1.getStreamDescription().getShards());

            LOG.trace("Current shard is: {} (in {})", currentShard, shardList);
            if (currentShard == null) {